package com.msb.mall.order.utils;


import com.msb.common.constant.OrderConstant;

import org.apache.rocketmq.spring.annotation.RocketMQMessageListener;
import org.apache.rocketmq.spring.core.RocketMQListener;

import org.springframework.stereotype.Component;
//监视器
@RocketMQMessageListener(topic = OrderConstant.ROCKETMQ_ORDER_TOPIC,consumerGroup = "${rocketmq.consumer.group}")
@Component
public class OrderMsgConsumer implements RocketMQListener<String> {

    //老师没有写
    @Override
    public void onMessage(String s) {
        // 30分钟用户没有支付就执行订单关单的逻辑
        System.out.println("消息收到了"+s);
    }
}
